package cn.com.greatwall.kafka.service;

import cn.com.greatwall.kafka.domain.Cluster;
import cn.com.greatwall.kafka.util.ZKUtil;

/**
 * @Author herw
 * @Time 2021-01-13 09:32:05
 * @Version 1.0
 * @Description: TODO(用一句话描述该文件做什么)
 */
public interface ZooKeeperService {
    /**
     * 测试连接zookeeper
     * @param resources /
     * @return /
     */
    boolean testConnectZookeeper(Cluster resources);
    
    /**
     * 获取zookeeper
     * @param clusterId
     * @return
     */
    ZKUtil getZooKeeper(String clusterId);
}
